package com.we.flink.userlabelplatform.table;

import java.sql.Timestamp;

public class TableTempToFixedRiskTag {

    public static final String KFKTABLE = "fdm.hhl01_temp_to_fixed_risk_tag";
    public static final String QUERYSQL =
            "select uid, "
                    + "task_end_time, output_time, update_time "
                    + "from "
                    + KFKTABLE
                    + " where task_type = 2 and update_time is not null";

    public long uid;
    public Timestamp task_end_time;
    public Timestamp output_time;
    public Timestamp update_time;

    public TableTempToFixedRiskTag() {}

    public TableTempToFixedRiskTag(
            long uid, Timestamp task_end_time, Timestamp output_time, Timestamp update_time) {
        this.uid = uid;
        this.task_end_time = task_end_time;
        this.output_time = output_time;
        this.update_time = update_time;
    }

    public long getUid() {
        return uid;
    }

    public Timestamp getTask_end_time() {
        return task_end_time;
    }

    public Timestamp getOutput_time() {
        return output_time;
    }

    public Timestamp getUpdate_time() {
        return update_time;
    }

    @Override
    public String toString() {
        return "TableTempToFixedRiskTag{"
                + "uid="
                + uid
                + ", task_end_time="
                + task_end_time
                + ", output_time="
                + output_time
                + ", update_time="
                + update_time
                + '}';
    }
}
